package com.bus.core.channels;

import com.bus.core.BusChannelClient;
import com.bus.core.bean.Input2OutputBean;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface OrderBusChannelClient extends BusChannelClient {

    String INPUT_ORDER = "inputOrder";
    String OUTPUT_ORDER = "outputOrder";
    String TOPIC="order";

    Input2OutputBean INPUT_2_OUTPUT_BEAN=new Input2OutputBean( OUTPUT_ORDER,INPUT_ORDER,TOPIC);

    @Input(INPUT_ORDER)
    SubscribableChannel inputOrder();

    @Output(OUTPUT_ORDER)
    MessageChannel outputOrder();
}
